<?php

/**
 * Subclass for performing query and update operations on the 'af_transaccion' table.
 *
 * 
 *
 * @package lib.model
 */ 
class AfTransaccionPeer extends BaseAfTransaccionPeer
{
  /*public static function loadDataFromFile($eliminarRegistrosAnteriores=false)
  {
    if($eliminarRegistrosAnteriores)
      AfTransaccionPeer::doDeleteAll();
    $resultado = array();
    $totalRegistros=0;
    $criteria = new Criteria();
    $criteria->add(CtControlPeer::CODIGO_ARCHIVO,'AF%', Criteria::LIKE);
    $archivoControl = CtControlPeer::doSelectOne($criteria);
    $archivo = @file(sfConfig::get('sf_upload_dir')."/".$archivoControl->getCodigoArchivo().'.TXT');
    if($archivo)
    {
      foreach ($archivo as $line_num => $line)
      {
        $datos = explode(",", $line);
        $transaccion = new AfTransaccion();
        $transaccion->setFacturaId(trim($datos[4]));
        $transaccion->setEntidadPrestadoraId(trim($datos[0]));
        $transaccion->setEntidadPrestadoraRazonSocial(trim($datos[1]));
        $transaccion->setEntidadPrestadoraTipoIdentificacionId(trim($datos[2]));
        $transaccion->setEntidadPrestadoraIdentificacion(trim($datos[3]));
        $transaccion->setFacturaFechaExpedicion(trim($datos[5]));
        $transaccion->setFacturaFechaInicio(trim($datos[6]));
        $transaccion->setFacturaFechaFinal(trim($datos[7]));
        $transaccion->setEntidadAdministradoraId(trim($datos[8]));
        $transaccion->setEntidadAdministradoraRazonSocial(trim($datos[9]));
        $transaccion->setNumeroContrato(trim($datos[10]));
        $transaccion->setPlanDeBeneficios(trim($datos[11]));
        $transaccion->setNumeroPoliza(trim($datos[12]));
        $transaccion->setCopago(trim($datos[13]));
        $transaccion->setCopagoNumero($datos[13]);
        $transaccion->setComision(trim($datos[14]));
        $transaccion->setComisionNumero($datos[14]);
        $transaccion->setDescuentos(trim($datos[15]));
        $transaccion->setDescuentosNumero($datos[15]);
        $transaccion->setNetoAPagar(trim($datos[16]));
        $transaccion->setNetoAPagarNumero($datos[16]);
        if($transaccion->save())
          $totalRegistros++;
      }
      $resultado['informacion']['AF']['registros-grabados'] = $totalRegistros;
    }
    else
      $resultado['errores']['AF'] = array('No se pudo leer el archivo '.$archivoControl->getCodigoArchivo());
    return $resultado;
  }*/
  public static function loadDataFromFile($eliminarRegistrosAnteriores=false)
  {
    if($eliminarRegistrosAnteriores)
      AfTransaccionPeer::doDeleteAll();
    $resultado = array();
    $totalRegistros=0;
    $criteria = new Criteria();
    $criteria->add(CtControlPeer::CODIGO_ARCHIVO,'AF%', Criteria::LIKE);
    $archivoControl = CtControlPeer::doSelectOne($criteria);
    $archivo = @file(sfConfig::get('sf_upload_dir')."/".$archivoControl->getCodigoArchivo().'.TXT');
    //$conexion = Propel::getConnection();
    $sql = "";
    if($archivo)
    {
      foreach ($archivo as $line_num => $line)
      {
         //VALUES ('SG40989','760010335901','CLINICAVERSALLESSA','NI','800048954','24/02/2009','01/10/2008','31/12/2008','EPS018','CAPITACIONS.O.S','','POS','0','0.00','0.0','0.0','0.00',0,0,0,0)
        $sql .= "INSERT INTO af_transaccion (FACTURA_ID,ENTIDAD_PRESTADORA_ID,ENTIDAD_PRESTADORA_RAZON_SOCIAL,ENTIDAD_PRESTADORA_TIPO_IDENTIFICACION_ID,ENTIDAD_PRESTADORA_IDENTIFICACION,FACTURA_FECHA_EXPEDICION,FACTURA_FECHA_INICIO,FACTURA_FECHA_FINAL,ENTIDAD_ADMINISTRADORA_ID,ENTIDAD_ADMINISTRADORA_RAZON_SOCIAL,NUMERO_CONTRATO,PLAN_DE_BENEFICIOS,NUMERO_POLIZA,COPAGO,COMISION,DESCUENTOS,NETO_A_PAGAR,COPAGO_NUMERO,COMISION_NUMERO,DESCUENTOS_NUMERO,NETO_A_PAGAR_NUMERO) VALUES (";
        $datos = explode(",", $line);
        
        $sql .= "'".trim($datos[4])."',";
        $sql .= "'".trim($datos[0])."',";
        $sql .= "'".trim($datos[1])."',";
        $sql .= "'".trim($datos[2])."',";
        $sql .= "'".trim($datos[3])."',";
        $sql .= "'".trim($datos[5])."',";
        $sql .= "'".trim($datos[6])."',";
        $sql .= "'".trim($datos[7])."',";
        $sql .= "'".trim($datos[8])."',";
        $sql .= "'".trim($datos[9])."',";
        $sql .= "'".trim($datos[10])."',";
        $sql .= "'".trim($datos[11])."',";
        $sql .= "'".trim($datos[12])."',";
        $sql .= "'".trim($datos[13])."',";
        
        $sql .= "'".trim($datos[14])."',";
        
        $sql .= "'".trim($datos[15])."',";
        
        $sql .= "'".trim($datos[16])."',";
        $sql .= $datos[13].",";
        $sql .= $datos[14].",";
        $sql .= $datos[15].",";
        $sql .= $datos[16].");";
        $totalRegistros++;
      }
      //$resultado['informacion']['AF']['registros-grabados'] = $totalRegistros;
      
      //$sentencia = $conexion->prepareStatement($sql);
      //$resultset = $sentencia->executeQuery();
      $conn_string = " host=localhost dbname=rips user=ripsadmin password=ripsadmin123";
      $conexion  = pg_connect($conn_string);
      $resultset = pg_query($conexion,$sql);
      
      if($resultset)
        $resultado['informacion']['AF']['registros-grabados'] = $totalRegistros;
    }
    else
      $resultado['errores']['AF'] = array('No se pudo leer el archivo '.$archivoControl->getCodigoArchivo());
    return $resultado;
  }
}
